//package com.huai.demo_test1.rocketmq;
//
//import com.huai.demo_test1.config.JmsConfig;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.client.exception.MQClientException;
//import org.apache.rocketmq.client.producer.DefaultMQProducer;
//import org.springframework.stereotype.Component;
//
///**
// * @author 淮晓欢
// * @date 2022/1/3
// **/
//@Slf4j
//@Component
//public class ProducerTest {
//    private DefaultMQProducer producer;
//
//    public ProducerTest() {
//        String producerGroup = "test_producer";
//        producer = new DefaultMQProducer(producerGroup);
//        producer.setVipChannelEnabled(false);
//        producer.setNamesrvAddr(JmsConfig.NAME_SERVER);
//        start();
//    }
//    /**
//     * 对象在使用之前必须要调用一次，只能初始化一次
//    */
//    private void start() {
//        try {
//            this.producer.start();
//        } catch (MQClientException e) {
//            e.printStackTrace();
//        }
//    }
//
//    public DefaultMQProducer getProducer() {
//        return producer;
//    }
//    /**
//     * 一般应用在上下文，使用上下文监听器，进行关闭
//     */
//    public void shutdown(){
//        this.producer.shutdown();
//    }
//}
